package com.csg.ses.service.ses.impl;

import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.csg.ses.vo.common.Result;
import com.csg.ses.vo.common.ResultStatus;
import lombok.RequiredArgsConstructor;
import com.csg.ses.common.utils.MybatisPlusUtil;

import com.csg.ses.dao.ses.YxzjkZwCsxxDao;
import com.csg.ses.entity.ses.YxzjkZwCsxxEntity;
import com.csg.ses.service.ses.YxzjkZwCsxxService;

import java.util.List;
import java.util.Map;

/**
 * 账务催收信息（营销中间库）
 * @author wangjun
 * @date 2020-11-18 15:53:40
 */
@Service
@RequiredArgsConstructor
public class YxzjkZwCsxxServiceImpl extends ServiceImpl<YxzjkZwCsxxDao, YxzjkZwCsxxEntity> implements YxzjkZwCsxxService {
    private final YxzjkZwCsxxDao yxzjkZwCsxxDao;

    @Override
    public Result retrieve(YxzjkZwCsxxEntity yxzjkZwCsxx, Long current, Long size) {
        try {
            Page<YxzjkZwCsxxEntity> page = MybatisPlusUtil.initPage(current, size, true);
            QueryWrapper<YxzjkZwCsxxEntity> qw = new QueryWrapper();
            return new Result(yxzjkZwCsxxDao.retrieve(page, qw), ResultStatus.SUCCESS);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException();
        }
    }

    /**
     * 获取待更新的任务号
     * @return
     */
    @Override
    public List<String> getTaskIdList() {
        return yxzjkZwCsxxDao.getTaskIdList();
    }

    @Override
    public void p_handle_phone_numbers(Map<String, Object> param) {
        yxzjkZwCsxxDao.p_handle_phone_numbers(param);
    }
}